package com.inji.spark.biz.listener;

import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;

import com.inji.spark.biz.service.kafka.KafkaReader;


/**
 * 
 * @author liukz
 *
 */
public class ApplicationStartup implements ApplicationListener<ContextRefreshedEvent> {

    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
    	//KafkaJavaProducer.initInjiKafkaProducer();
    	KafkaReader.initInjiKafkaReader();
    }
}